package studio.raptor.extractor.segment.service;

import org.springframework.stereotype.Service;
import studio.raptor.databus.client.DatabusConfig;
import studio.raptor.databus.client.DatabusConsumer;
import studio.raptor.databus.client.DatabusConsumerBuilder;
import studio.raptor.databus.command.ActiveMQObjectMessage;
import studio.raptor.extractor.segment.config.ServerConfig;

/**
 * Created by liuyong8 on 2017/7/24.
 */
@Service
public class MQService {



    public void getMQEvent(String bizName,String eventName,Integer kindId) throws Exception{

        DatabusConfig config = new DatabusConfig(bizName);
        DatabusConsumerBuilder consumerBuilder = new DatabusConsumerBuilder(config);
        DatabusConsumer consumer =
                consumerBuilder.createClientACK(eventName, kindId);


    }

}
